package org.ring.common.transport;

import java.util.concurrent.CompletableFuture;

/**

 * @since 2024-07-21 20:53
 */
public interface MessageHandler<M,R> {

    CompletableFuture<R> handle(Connection connection,M input);

}
